package com.konsung.ksdc.common.mqtt;

import com.konsung.ksdc.bean.MqttMsgBean;

/**
 * 创建者     kgh
 * 创建时间   2016/5/23 11:18
 * 更新者     $Author$
 * 更新时间   $Date$
 * 更新描述   ${TODO}
 */
public interface KsdcMqttMsgCallback {

    /**
     * 数据接收回调方法
     *
     * @param topicName 接收的主题
     * @param data 接收到的数据
     * @param qos 消息优先级
     * @param retained 是否保留消息
     */
    void onMessageReceived(String topicName, MqttMsgBean data, int qos, boolean retained);

}
